const express = require('express')
const app = express()
let bodyParser = require('body-parser')
const MY_SQL = require('mysql-ithm')

app.use(express.static('dist/build/h5'))
app.use(bodyParser.urlencoded({ extended: false }))
app.use(bodyParser.json())

//连接数据库
//如果数据库存在则连接，不存在则会自动创建数据库
MY_SQL.connect({
  host: 'localhost', //数据库地址
  port: '3306',
  user: 'root', //用户名，没有可不填
  password: 'root', //密码，没有可不填
  database: 'daigou_mall' //数据库名称
})

//创建Model(表格模型：负责增删改查)
//如果table表格存在则连接，不存在则自动创建
let userModel = MY_SQL.model('users', {
  username: String,
  password: String
})
userModel.insert({username:'admin',password:'admin'},(err,results)=>{
  console.log(err);
  console.log(results);
  if(!err) console.log('增加成功');
});

app.post('/register', (req, res) => {
  console.log(req.body) // mobile:111,password:111
  let { mobile, password } = req.body
  // 查询用户名是否存在
  
  userModel.find(`username="${mobile}"`, (err, results) => {
    if (err) {
      console.log(err)
      res.send({
        code: 501,
        msg: '服务器内部错误'
      })
    } else {
      if (results.length > 0) {
        res.send({
          code: 401,
          msg: '用户已经注册'
        })
      } else {
        // 用户未注册
        userModel.insert(
          {
            username: mobile,
            password
          },
          (err, results) => {
            if (err) {
              res.send({
                code: 500,
                msg: '服务器内部错误'
              })
            } else {
              res.send({
                code: 200,
                msg: '注册成功'
              })
            }
          }
        )
      }
    }
  })
})

app.listen(80, () => {
  console.log('服务器开启成功！！')
})
